package coop.tecso.capacitaciones.threads.mensaje;

public class Emisor extends Thread {
	private Canal canal;
	private String mensaje;

	public Emisor(Canal canal, String mensaje) {
		super();
		this.canal = canal;
		this.mensaje = mensaje;
	}

	@Override
	public void run() {
		// Envia el mensaje al canal
		canal.set(mensaje);
	}

}
